package com.activemq.provider.controller;


import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.jms.Queue;

@RestController
public class ProviderController { //处理生产者相关的请求，同时还要把消息（数据）发送到消息中间件

    //注入存放消息的队列
    @Autowired //自动注入存放消息的队列
    private Queue queue;

    //自动注入springboot封装的模板工具类
    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;
    //发送请求
    @RequestMapping("/send")
    public void send(String name) {
        //方法一：添加消息到消息队列
        //传到service层进行逻辑判断
        //把name的值存放到消息队列
        jmsMessagingTemplate.convertAndSend(queue, name);
        //方法二：这种方式不需要手动创建queue，系统会自行创建名为test的队列
        //jmsMessagingTemplate.convertAndSend("test", name);
    }
}
